<?php
/**
 *
 * 本接口用于将client_id与用户绑定(bindUid)，并加入特定的群组(joinGroup)
 * bindUid后就可以通过接口Gateway::sendToUid向uid发送数据(见send_message.php)
 * joinGroup后就可以收到对应群组的消息。用接口Gateway::sendToGroup向群组发送消息(见send_message.php)
 *
 * 本接口中写死了让所有用户加入101群组，101是随意定义的，你也可以定义成其它的值如 123、abc，
 * 如果你的现有系统有群组数据，可以使用你的群组数据。
 * 注意：加入的群组必须在init.php返回的json中有定义
 *
 */
use Lib\Db;

require_once __DIR__ . '/__init.php';
_session_start();
$message_type = $_GET['message_type'];
if($message_type == 'check_online' || $message_type == 'check_admin_online'){
    $status = $_GET['status'];
    $user_id = $_GET['user_id'];
    $reseller_id = $_GET['reseller_id'];
    $service = isset($_GET['service'])?$_GET['service']:1;

    if($message_type == 'check_online'){
        $pay_message = array(
            'message_type' => $message_type,
            'user_id' => $user_id,
            'reseller_id' => $reseller_id,
            'status' => $status,
            'service' => $service,
        );
        $uid = "user-".$user_id;
    }else if($message_type == 'check_admin_online'){
        $pay_message = array(
            'message_type' => $message_type,
            'admin_id' => $user_id,
            'reseller_id' => $reseller_id,
            'status' => $status,
            'service' => $service,
        );
        $uid = "admin-".$user_id;
    }

    Gateway::sendToAll(json_encode($pay_message));
    //Gateway::sendToUid($user_id, json_encode($pay_message));
//    $ClientId_arr = Gateway::getClientIdByUid($uid);
//    foreach ($ClientId_arr as $kk=>$vv){
//        if(Gateway::isOnline($vv)){
//            Gateway::sendToClient($vv, json_encode($pay_message));
//        }
//    }



// 返回json数据
    exit_json(array('code'=>0,'ClientId_arr'=>$ClientId_arr));
}else{
    exit('error');
}

